package cn.consumer;

import java.util.concurrent.ArrayBlockingQueue;

public class TestMain {
   
	public static void main(String[] args){
		 int queueSize=10;
		 ArrayBlockingQueue<Integer> queue=new ArrayBlockingQueue<Integer>(queueSize);
		 new Producer(queue).start();
		 new Consumer(queue).start();		 
	}
}
